package com.chunguang.netty.comon;

import java.util.Queue;

public class Consumer implements Runnable{
	
	private Queue<String> queue;
	

	@Override
	public void run() {
		String poll = queue.poll();
		System.err.println("data"+poll);
	}
	

}
